6ef5d7fa9f92a051738ff57f2102bd7041ae3443,camel-jms/src/test/java/org/apache/camel/jms/JmsRouteTest.java,JmsRouteTest,testJmsRoute,#,33
Before Change
container.addComponent("activemq", jmsComponent(connectionFactory));
// lets add some routes
container.routes(new RouteBuilder() {
public void configure() {
from("jms:activemq:FOO.BAR").to("jms:activemq:FOO.BAR");
}
});
}
}
After Change
container.addComponent("activemq", jmsComponent(template));
// lets add some routes
container.routes(new RouteBuilder() {
public void configure() {
from("jms:activemq:test.a").to("jms:activemq:test.b");
from("jms:activemq:test.b").process(new Processor<JmsExchange>() {
public void onExchange(JmsExchange exchange) {
System.out.println("Received exchange: " + exchange.getRequest());
}
});
}
});
// now lets fire in a message
Endpoint<JmsExchange> endpoint = container.endpoint("jms:activemq:test.a");